package com.king.ml.app.test2

import com.king.ml.annotation.Task
import com.king.ml.base.BaseTask
import com.king.ml.enums.TaskNameEnum
import org.apache.spark.SparkConf


@Task
class Test2Task extends BaseTask{
  override def taskName: TaskNameEnum.Value = TaskNameEnum.Test2

  override def initConf(sparkConf: SparkConf): SparkConf = {
    sparkConf
      .set("spark.yarn.executor.memoryOverhead", "4096")
      .set("spark.shuffle.file.buffer", "64k")
      .set("spark.kryoserializer.buffer.max", "256m")
      .set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
  }

}
